//package cur.component.redis.queue;
//
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//import org.springframework.data.redis.connection.RedisConnectionFactory;
//import org.springframework.data.redis.listener.ChannelTopic;
//import org.springframework.data.redis.listener.RedisMessageListenerContainer;
//
//@Configuration
//public class RedisMessageListenerConfig {
//    @Bean
//    public RedisMessageListenerContainer getRedisMessageListenerContainer(
//            RedisConnectionFactory redisConnectionFactory,
//            RedisMessageListener redisMessageListenerListener) {
//
//        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
//        container.setConnectionFactory(redisConnectionFactory);
//        container.addMessageListener(redisMessageListenerListener, new ChannelTopic(PubSubRedisQueue.KEY));
//        return container;
//    }
//}
